NetworkClient

StockSharp.Fix.Native

Clase base abstracta para clientes de red UDP.

Hereda de: BaseLogReceiver

Implementa: INetworkClient, ILogReceiver, ILogSource, IDisposable, IPacketProcessor

Constructores

protected NetworkClient(IUdpDialect dialect, string name, MulticastSourceAddress address, Func<TNetworkClient, IMemoryOwner<byte>, List<Message>, bool> processMessage, IPacketReceiverFactory receiverFactory)

networkClient = NetworkClient(dialect, name, address, processMessage, receiverFactory)

Inicia una nueva instancia de la clase NetworkClient.

dialect: El dialecto UDP.
name: El nombre del cliente.
address: La dirección fuente multicast.
processMessage: Función para procesar mensajes recibidos.
receiverFactory: IPacketReceiverFactory

Propiedades

Dialect

public IUdpDialect Dialect { get; }

value = networkClient.Dialect

Consigue el dialecto UDP asociado con este cliente.

FullMode

public PacketQueueFullModes FullMode { get; set; }

value = networkClient.FullMode
networkClient.FullMode = value

Comportamiento cuando la cola de paquete está llena.

IsEnabled

public bool IsEnabled { get; }

value = networkClient.IsEnabled

Enabled.

MaxIncomingQueueSize

public int MaxIncomingQueueSize { get; }

value = networkClient.MaxIncomingQueueSize

Paquetes UDP de entrada máxima por alimento antes de que se dejen caer nuevos paquetes.

MaxUdpDatagramSize

public int MaxUdpDatagramSize { get; }

value = networkClient.MaxUdpDatagramSize

Tamaño máximo de los datagramas UDP.

Name

public override string Name { get; }

value = networkClient.Name

Consigue el nombre del cliente.

Métodos

AllocatePacket

public IMemoryOwner<byte> AllocatePacket(int size)

result = networkClient.AllocatePacket(size)

Para asignar un paquete del tamaño especificado.

size: El tamaño del paquete para asignar.

Devuelve: El paquete.

Connect

public void Connect()

networkClient.Connect()

Conectar al sistema de comercio.

Disconnect

public void Disconnect()

networkClient.Disconnect()

Desconectarse del sistema comercial.

DisposeManaged

protected override void DisposeManaged()

networkClient.DisposeManaged()

Libera recursos.

DisposePacket

public void DisposePacket(IMemoryOwner<byte> packet, string reason)

networkClient.DisposePacket(packet, reason)

Desecha el paquete con la razón especificada.

packet: El paquete.
reason: La razón especificada.

ErrorHandler

public void ErrorHandler(Exception e, int numErrors, bool isFatal)

networkClient.ErrorHandler(e, numErrors, isFatal)

Maneja errores que ocurren durante el procesamiento del paquete.

e: La excepción encontrada.
numErrors: El recuento de errores.
isFatal: Indica si el error es fatal.

ProcessNewPacket

public ValueTask<bool> ProcessNewPacket(IMemoryOwner<byte> packet, int length, CancellationToken cancellationToken)

result = networkClient.ProcessNewPacket(packet, length, cancellationToken)